const mysql = require('mysql');

module.exports = (sql, params = []) => {
    // 创建 mysql 连接配置
    const con = mysql.createConnection({
        host: 'localhost',
        port: 3306,
        user: 'root',
        password: 'root',
        database: 'zk2-invoice',
    });

    // 尝试建立连接
    con.connect((error) => {
        if (error) return console.log('连接数据库服务器失败', error.message);
    });

    // 执行 SQL 语句
    return new Promise((resolve, reject) => {
        // 要执行的异步操作
        con.query(sql, params, (error, data) => {
            if (error) return reject(error);
            resolve(data);
        });
        // 关闭连接
        con.end();
    });
};
